import redis
import time
import json
client = redis.Redis()
print('开始接收消息...')
last_message_time = None  # 初始化时间记录变量。
while True:  # 使用一个无限循环来持续接收数据 。
    data = client.get('message')  # 读取 Redis 中 名字为 message 的 字符串 。
    if not data:  # message这个Key可能不存在,此时返回None。遇到这种情况就等待1秒以后跳过本次循环。
        time.sleep(1)
        continue
    info = json.loads(data.decode())  # 使用 json 模块解析 JSON 字符串,以获取信息和发送时间
    message = info['message']
    send_time = info['time']
    if send_time == last_message_time:  # 如果信息的发送时间与上一条信息的发送时间一样,则说明是同一条信息,不需要打印出来。
        #  这条信息已经接收过了，不需要重复接收
        time.sleep(1)
        continue
    print(f'接收到新信息：{message}, 发送时间为：{send_time}')
    last_message_time = send_time  # 更新时间记录变量。
